import socket
import threading


# 处理客户端请求的函数
def handle_client(new_socket, ip_port):

    # 循环接收客户端的数据
    while True:
        # 接收客户端发送的数据
        recv_data = new_socket.recv(1024)
        if recv_data:
            # 对二进制数据进行解码
            recv_content = recv_data.decode("gbk")
            print("接收客户端的数据为:", recv_content)
            # 发送数据
            new_socket.send("服务端".encode("gbk"))
        else:
            print("客户端下线：", ip_port)
            break

    # 关闭套接字
    new_socket.close()

if __name__ == '__main__':
    # 创建tcp服务端套接字
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 设置端口号复用，程序退出端口号立即释放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    # 绑定端口号
    tcp_server_socket.bind(("", 9090))
    # 设置监听
    tcp_server_socket.listen(128)

    # 循环等待接受客户端的连接请求
    while True:
        # 等待接受客户端的连接请求
        new_socket, ip_port = tcp_server_socket.accept()
        print("客户端为:", ip_port)
        # 创建子线程，专门负责处理客户端请求
        sub_thread = threading.Thread(target=handle_client, args=(new_socket, ip_port))
        # 设置守护主线程
        sub_thread.setDaemon(True)
        sub_thread.start()

    # 提示： 服务端程序需要一直运行，所以tcp服务端的套接字可以不用关闭
    # tcp_server_socket.close()
